package com.qianfeng.chinamobile.strategy.mq;

import com.qianfeng.smsplatform.common.constants.RabbitMqConsants;
import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

public interface LocalCacheChangeStream {

    @Input(RabbitMqConsants.TOPIC_EXECFILTERS_UPDATE)//接受过滤器发生变化的 stream
    SubscribableChannel filter_change_channel();
}
